package com.yixun.listener;

import com.yixun.component.SpringUtil;
import com.yixun.service.HeatUpService;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.util.StringUtils;

//用到多条数据就用redis
public class SubscribeListener implements MessageListener{

    HeatUpService heatUpService = SpringUtil.getBean(HeatUpService.class);
    /**
     * <h2>消息回调</h2>
     * @param message {@link Message} 消息体 + ChannelName       这个会进入
     * @param pattern 订阅的 pattern, ChannelName 的模式匹配       订阅breakdown主题   不能重复消费
     * */
    @Override
    public void onMessage(Message message, byte[] pattern) {

        String siteNo = new String(message.getBody());


        //判断温差是否大于30  当前通道
        //也是消费redis中发布的原数据   //温差跟30相比较
        // * @Desc: 站点升温过快故障--异步分析  比较通道连续两条数据
        heatUpService.siteHeatUp(siteNo);
    }

}
